package com.hen.web.henweb.config;

import com.hen.web.henweb.common.QueueConstant;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @author 狠穿
 * @version 1.0.0
 * @date 2023/3/31
 * @function RabbitMQ配置类
 */
@Configuration
public class RabbitConfig {

    /**
     * 向Spring容器注册一个专门用于建表的队列
     * @return
     */
    @Bean
    public Queue createTableQueue(){
        return new Queue(QueueConstant.CREATE_TABLE_QUEUE);
    }

    /**
     * 向Spring容器注册一个专门用于修复表的队列
     * @return
     */
    @Bean
    public Queue repairTableQueue(){
        return new Queue(QueueConstant.REPAIR_TABLE_QUEUE);
    }
}
